@startuml
namespace reader {
    class Reader << (S,Aquamarine) >> {
        - log *zap.SugaredLogger
        - consumer sarama.ConsumerGroup
        - topic string

        + Read(ctx context.Context, msgChan <font color=blue>chan</font> types.SSPPartnerMessage)

    }
    class consumer << (S,Aquamarine) >> {
        - log *zap.SugaredLogger
        - messages <font color=blue>chan</font> types.SSPPartnerMessage
        - ready <font color=blue>chan</font> bool

        + Setup(session sarama.ConsumerGroupSession) error
        + Cleanup( sarama.ConsumerGroupSession) error
        + ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

    }
}


@enduml
